package com.springboot.study.config;

import org.springframework.amqp.core.Queue;
import org.springframework.amqp.core.QueueBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
/**
 * 这是最基本的模式：一个生产者发送消息到队列，一个消费者接收消息。
 */
@Configuration
public class SimpleQueueConfig {
    // 队列名称常量
    public static final String SIMPLE_QUEUE = "simple.queue";
    /**
     * 声明简单队列（持久化）
     */
    @Bean
    public Queue simpleQueue() {
        return QueueBuilder.durable(SIMPLE_QUEUE).build();
    }
}
